#Java - Code Snippets for '#Org.apache.spark.network.server.TransportServer'

#Java - Code Snippets for '#Org.apache.spark.network.server.TransportServer' - 2 code snippet(s) found

Sample 1. Code Sample / Example / Snippet of org.apache.spark.network.server.TransportServerBootstrap

  public void beforeEach() throws IOException {

    TransportContext context =

      new TransportContext(conf, new ExternalShuffleBlockHandler(conf, null));

    TransportServerBootstrap bootstrap = new SaslServerBootstrap(conf,

        new TestSecretKeyHolder("my-app-id", "secret"));

    this.server = context.createServer(Arrays.asList(bootstrap));

  }

_{Like Feedback org.apache.spark.network.server.TransportServerBootstrap}

Sample 2. Code Sample / Example / Snippet of org.apache.spark.network.server.TransportServer

  public void testNoSaslServer() {

    RpcHandler handler = new TestRpcHandler();

    TransportContext context = new TransportContext(conf, handler);

    clientFactory = context.createClientFactory(

      Lists.<TransportClientBootstrap>newArrayList(

        new SaslClientBootstrap(conf, "app-1", secretKeyHolder)));

    TransportServer server = context.createServer();

    try {

      clientFactory.createClient(TestUtils.getLocalHost(), server.getPort());

    } catch (Exception e) {

      assertTrue(e.getMessage(), e.getMessage().contains("Digest-challenge format violation"));

    } finally {

      server.close();

    }

  }

_{Like Feedback org.apache.spark.network.server.TransportServer}

Search Java Code Snippets